package com.gitee.xhs;

import com.gitee.xhs.sampleRecod.transactionRecord.Transaction;
import org.apache.flink.api.common.eventtime.WatermarkGenerator;
import org.apache.flink.api.common.eventtime.WatermarkGeneratorSupplier;

/**
 * @author BigHead
 * @date 2022/7/18 14:35
 * @description CustomDefaultWatermarkGeneratorSupplier
 */
public class CustomDefaultWatermarkGeneratorSupplier implements WatermarkGeneratorSupplier<Transaction> {

    public static final String CUSTOM_DEFAULT_WATERMARK_GENERATOR_SUPPLIER = "CustomDefaultWatermarkGeneratorSupplier";

    @Override
    public WatermarkGenerator<Transaction> createWatermarkGenerator(Context context) {
        return new CustomDefaultWatermarkGenerator();
    }
}
